package com.accenture.automation.biz.api.producer.iface;

import com.accenture.automation.biz.api.bean.ResponseBaseBean;

public interface ProducerService {
	public int sendKafka(String topic, String key, String message);

	/**
	 * 处理请求数据，根据AppId & InterfaceCode信息创建MessageQueue
	 * 
	 * @param topic
	 * @param message
	 * @param key
	 * @return
	 */
	public ResponseBaseBean<Object> apiCreate(String topic, String message, String key);
}
